package com.demo.flink

import org.apache.flink.api.scala._

object ListSource {
  def main(args: Array[String]): Unit = {
    val env = ExecutionEnvironment.getExecutionEnvironment
    val result = env.fromCollection(List("hadoop","hbase","spark"))
    result.print()
  }
}
